package io.mqttpush.mqttserver.config;

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @author tianzhenjiu
 * @date 2020/4/27 17:24
 */
public class TaskManager {


    private int bossthreads = Runtime.getRuntime().availableProcessors();

    ThreadPoolExecutor threadPoolExecutor= new ThreadPoolExecutor(bossthreads, bossthreads,
            0L, TimeUnit.MILLISECONDS,
            new LinkedBlockingQueue<Runnable>());

}
